package com.yanduo.utils

import org.apache.spark.sql.types._

/**
  * @author Gerry chan
  * @version 1.0
  */
object SchemaUtils {
  //定义字段信息
  val logStructType = StructType(Seq(
    StructField("sessionid", StringType),
    StructField("advertisersid", IntegerType),
    StructField("adorderid", IntegerType),
    StructField("adcreativeid", IntegerType),
    StructField("adplatformproviderid", IntegerType),
    StructField("sdkversion", IntegerType),
    StructField("adplatformkey", IntegerType),
    StructField("adpprice", DoubleType),
    StructField("traffic", LongType),
    StructField("ip", StringType),
    StructField("city", StringType),
    StructField("time", StringType),
    StructField("day", StringType)
  ))
}
